package com.zho.common.jms.impl;

import java.io.Serializable;

import javax.jms.JMSException;
import javax.jms.Queue;

import com.zho.common.jms.JmsQueueSender;

public class JmsQueueSenderImpl extends JmsSenderBase implements JmsQueueSender {

    private Queue queueTest1;
    private Queue queueTest2;
    private Queue queuePostToSNS;
    
    /**
     * Send Queue 1
     * @throws JMSException
     */
    public void sendQueue1(Serializable message) throws JMSException {
    	sendMessages(message, queueTest1);
    }
    
    /**
     * Send Queue 2
     * @throws JMSException
     */
    public void sendQueue2(Serializable message) throws JMSException {
    	sendMessages(message, queueTest2);
    }
    
    /**
     * Send queuePostToSNS
     * @throws JMSException
     */
    public void sendPostToSNS(Serializable message) throws JMSException {
    	sendMessages(message, queuePostToSNS);
    }

    /**
     *	Set bean for queues 
      */
	public void setQueueTest1(Queue queueTest1) {
		this.queueTest1 = queueTest1;
	}
	public void setQueueTest2(Queue queueTest2) {
		this.queueTest2 = queueTest2;
	}

	public void setQueuePostToSNS(Queue queuePostToSNS) {
		this.queuePostToSNS = queuePostToSNS;
	}
 


}
